//package com.whale.cloud.util.kafka;
//
//import org.apache.kafka.clients.producer.RecordMetadata;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.core.KafkaOperations;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.kafka.support.ProducerListener;
//import org.springframework.stereotype.Component;
//import lombok.Data;
//
///** Created by Abel on 2017/5/25. */
//@Data
//@Component
//public class MKafkaProducer {
//
//  //  @Autowired private KafkaTemplate kafkaTemplate;
//
//  //  public void send(String topic, String data) {
//  //
//  //    kafkaTemplate.send(topic, data);
//  //    kafkaTemplate();
//  //    kafkaTemplate.execute(
//  //        new KafkaOperations.ProducerCallback<String, String, Object>() {
//  //          @Override
//  //          public Object doInKafka(
//  //              org.apache.kafka.clients.producer.Producer<String, String> producer) {
//  //            return null;
//  //          }
//  //        });
//  //
//  //    //消息发送的监听器，用于回调返回信息
//  //    kafkaTemplate.setProducerListener(
//  //        new ProducerListener<String, String>() {
//  //          @Override
//  //          public void onSuccess(
//  //              String topic,
//  //              Integer partition,
//  //              String key,
//  //              String value,
//  //              RecordMetadata recordMetadata) {}
//  //
//  //          @Override
//  //          public void onError(
//  //              String topic, Integer partition, String key, String value, Exception exception) {}
//  //
//  //          @Override
//  //          public boolean isInterestedInSuccess() {
//  //            return false;
//  //          }
//  //        });
//  //  }
//}
